package com.yasaka.stock.service;

import com.cloopen.rest.sdk.CCPRestSDK;
import com.cloopen.rest.sdk.CCPRestSmsSDK;
import com.twilio.Twilio;
import com.twilio.rest.api.v2010.account.Message;
import com.twilio.type.PhoneNumber;
import com.yasaka.stock.dao.EclConfigMapper;
import com.yasaka.stock.exception.MyException;
import com.yasaka.stock.vo.EclConfigVo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.ResourceBundle;
import java.util.Set;

@Service
@Slf4j
public class MessageService {

    private static final ResourceBundle RESOURCE_BUNDLE = ResourceBundle.getBundle("sms");

    @Value("${yuntongxun.domain}")
    private String domain;
    @Value("${yuntongxun.port}")
    private String port;
    @Value("${yuntongxun.acountSid}")
    private String acountSid;
    @Value("${twilio.twilioSid}")
    private String twilioSid;
    @Value("${twilio.twilioToken}")
    private String twilioToken;
    @Value("${twilio.twilioPhone}")
    private String twilioPhone;

    @Autowired
    EclConfigMapper eclConfigMapper;

    /**
     * 发送短信服务(容联云通讯)(根据templateId来区别是发送验证码还是订单通知)
     *
     * @param templateId
     * @param mobile
     * @param info
     * @return
     * @throws Exception
     */
    public boolean sendSms(String planform, String templateId,String mobile,String info) throws MyException {
        EclConfigVo vo = eclConfigMapper.findByType("WHITE_LIST");
        String whiteList = vo.getConfigValue();
        if(!StringUtils.contains(whiteList,mobile)){
            log.error("phone not in whiteList=" + mobile);
            throw new MyException("phone not in whiteList=" + mobile);
//            return false;
        }
        String[] infos = null;
        if(StringUtils.isNotBlank(info) && StringUtils.contains(info,",")){
            infos = info.split(",");
        }
        boolean result = false;
        //初始化SDK
        CCPRestSmsSDK restAPI = new CCPRestSmsSDK();
        //******************************注释*********************************************
        //*初始化服务器地址和端口                                                       *
        //*沙盒环境（用于应用开发调试）：restAPI.init("sandboxapp.cloopen.com", "8883");*
        //*生产环境（用户应用上线使用）：restAPI.init("app.cloopen.com", "8883");       *
        //*******************************************************************************
        restAPI.init(domain, port);
        //******************************注释*********************************************
        //*初始化主帐号和主帐号令牌,对应官网开发者主账号下的ACCOUNT SID和AUTH TOKEN     *
        //*ACOUNT SID和AUTH TOKEN在登陆官网后，在“应用-管理控制台”中查看开发者主账号获取*
        //*参数顺序：第一个参数是ACOUNT SID，第二个参数是AUTH TOKEN。                   *
        //*******************************************************************************
        String appId = RESOURCE_BUNDLE.getString(planform+ ".appId");
        String authToken = RESOURCE_BUNDLE.getString(planform+ ".authToken");
        restAPI.setAccount(acountSid, authToken);
        //******************************注释*********************************************
        //*初始化应用ID                                                                 *
        //*测试开发可使用“测试Demo”的APP ID，正式上线需要使用自己创建的应用的App ID     *
        //*应用ID的获取：登陆官网，在“应用-应用列表”，点击应用名称，看应用详情获取APP ID*
        //*******************************************************************************
        restAPI.setAppId(appId);
        //******************************注释****************************************************************
        //*调用发送模板短信的接口发送短信                                                                  *
        //*参数顺序说明：                                                                                  *
        //*第一个参数:是要发送的手机号码，可以用逗号分隔，一次最多支持100个手机号                          *
        //*第二个参数:是模板ID，在平台上创建的短信模板的ID值；测试的时候可以使用系统的默认模板，id为1。    *
        //*系统默认模板的内容为“【云通讯】您使用的是云通讯短信模板，您的验证码是{1}，请于{2}分钟内正确输入”*
        //*第三个参数是要替换的内容数组。																														       *
        //**************************************************************************************************
        //**************************************举例说明***********************************************************************
        //*假设您用测试Demo的APP ID，则需使用默认模板ID 1，发送手机号是13800000000，传入参数为6532和5，则调用方式为           *
        //*result = restAPI.sendTemplateSMS("13800000000","1" ,new String[]{"6532","5"});																		  *
        //*则13800000000手机号收到的短信内容是：【云通讯】您使用的是云通讯短信模板，您的验证码是6532，请于5分钟内正确输入     *
        //*********************************************************************************************************************
        HashMap<String, Object> rtn = restAPI.sendTemplateSMS(mobile,templateId,infos);
        log.info("sendSms rtn=" + rtn);
        if("000000".equals(rtn.get("statusCode"))){
            //正常返回输出data包体信息（map）
            HashMap<String,Object> data = (HashMap<String, Object>) rtn.get("data");
            Set<String> keySet = data.keySet();
            for(String key:keySet){
                Object object = data.get(key);
                log.info(key +" = "+object);
            }
            result = true;
        }else{
            //异常返回输出错误码和错误信息
            String e = "错误码=" + rtn.get("statusCode") +" 错误信息= "+rtn.get("statusMsg");
            result = false;
            log.error(e);
            throw new MyException("send message error=" + e);
        }
        return result;
    }

    /**
     * 发送语音服务(容联云通讯)(根据templateId来区别是发送验证码还是订单通知)
     *
     * @param planform
     * @param templateId
     * @param mobile
     * @param info
     * @return
     * @throws Exception
     */
    public boolean sendSmsCall(String planform, String templateId,String mobile,String info) throws MyException {
        EclConfigVo vo = eclConfigMapper.findByType("WHITE_LIST");
        String whiteList = vo.getConfigValue();
        if(!StringUtils.contains(whiteList,mobile)){
            log.error("phone not in whiteList=" + mobile);
            throw new MyException("phone not in whiteList=" + mobile);
//            return false;
        }
        boolean result = false;
        CCPRestSDK restAPI = new CCPRestSDK();
        restAPI.init(domain, port);// 正式
        String appId = RESOURCE_BUNDLE.getString(planform+ ".appId");
        String authToken = RESOURCE_BUNDLE.getString(planform+ ".authToken");
        restAPI.setAccount(acountSid, authToken);
        //******************************注释*********************************************
        //*初始化应用ID                                                                 *
        //*测试开发可使用“测试Demo”的APP ID，正式上线需要使用自己创建的应用的App ID     *
        //*应用ID的获取：登陆官网，在“应用-应用列表”，点击应用名称，看应用详情获取APP ID*
        //*******************************************************************************
        restAPI.setAppId(appId);
        HashMap<String, Object> rtn = restAPI.landingCall(mobile, null, info, mobile, "",1, "", "", "", "", "", "", "");
        log.info("SDKTestLandingCall result=" + rtn);
        if("000000".equals(rtn.get("statusCode"))){
            //正常返回输出data包体信息（map）
            HashMap<String,Object> data = (HashMap<String, Object>) rtn.get("data");
            Set<String> keySet = data.keySet();
            for(String key:keySet){
                Object object = data.get(key);
                log.info(key +" = "+object);
            }
        }else{
            //异常返回输出错误码和错误信息
            String e = "错误码=" + rtn.get("statusCode") +" 错误信息= "+rtn.get("statusMsg");
            result = false;
            log.error(e);
            throw new MyException("send message error=" + e);
        }
        return result;
    }

    /**
     * 给国外手机发送短信
     * @param areaCode  国家地区区号
     * @param mobile  手机号
     * @param content 消息内容
     * @return
     */
    public boolean sendForeignSms(String areaCode,String mobile,String content) throws MyException {
        boolean rtn = false;
        try {
            log.info("twilioSid==="+twilioSid);
            log.info("twilioToken==="+twilioToken);
            Twilio.init(twilioSid, twilioToken);
            log.info("twilioPhone==="+twilioPhone);
            Message message = Message.creator(new PhoneNumber(areaCode+mobile),new PhoneNumber(twilioPhone),content).create();
            log.info("Twilio短信发送的Message===" + message);
            rtn = true;
        } catch (Exception e) {
            log.error(mobile + "Twilio国外手机号发送Exception==="+e.getMessage());
            throw new MyException(mobile + "Twilio国外手机号发送Exception==="+e.getMessage());
        }
        return rtn;
    }


}
